// 引入模块
const mysql = require('mysql');
const pool = mysql.createPool({
    // 连接数量
    connectionLimit: 10,
    // 本地
    host: 'localhost',
    // 用户名
    user: 'root',
    // 密码
    password: 'root',
    // 数据库名称
    database: 'bigevent',
});
// 获取图书
function getBooks() {
    return new Promise((resolve, reject) => {
        // 查询
        pool.query(`select * from book order by id desc`, function (err, results) {
            if (err) {
                reject(err);
            } else {
                resolve(results);
            }
        })
    })
}

// 删除图书
function delBook(id) {
    return new Promise((resolve, reject) => {
        // 查询
        pool.query(`delete from book where id = ?`, id, function (err, results) {
            if (err) {
                reject(err);
            } else {
                resolve(results);
            }
        })
    })
}
// 添加图书
function addBook(obj) {
    return new Promise((resolve, reject) => {
        // 查询
        pool.query(`insert into book set ?`, obj, function (err, results) {
            if (err) {
                reject(err);
            } else {
                resolve(results);
                /* OkPacket {
                    fieldCount: 0,
                    affectedRows: 1,
                    insertId: 15,
                    serverStatus: 2,
                    warningCount: 0,
                    message: '',
                    protocol41: true,
                    changedRows: 0
                } */
            }
        })
    })
}


module.exports = {
    getBooks,
    delBook,
    addBook,
    pool
}